package com.oct.ywsc.core.bean;

import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;

@Deprecated
@Slf4j
public class KafkaConsumerListener {

//    /**
//     * kafka消息处理类
//     *
//     * @param consumerRecord
//     */
//    public void listen(ConsumerRecord<String, String> consumerRecord) throws Exception {
//        try {
//            String value = (String) consumerRecord.value();
//            log.info("监听Kafka消息：" + value);
//            // 实际业务处理逻辑
//        }catch (Exception e){
//            log.error("监听Kafka消息异常：" , e);
//        }
//    }
}
